/**
 * 
 */
package com.leo.jdkcore.kafka;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Description:
 * 
 * @author lianliang
 * @date 2017年12月9日 下午3:14:55
 */
public class RequestService {
	private static final Logger LOG = LoggerFactory.getLogger(RequestService.class);

	private KafkaReaderContext context;

	/**
	 * @param msg
	 * @param context
	 */
	public RequestService(KafkaReaderContext context) {
		this.context = context;
	}

	/**
	 * @return
	 */
	public void execute(String msg) {
		try {
			System.out.println("consumer msg: " + msg);
		} catch (Exception e) {
			LOG.error("消费发生异常：{}", e);
		}
	}

}
